write{
  i++;
}
main{
  final long start=System.currentTimeMillis();
  ch.pipeline().addLast(new RedisCommandEncoder(),new RedisReplyDecoder(),new ChannelInboundMessageHandlerAdapter<Reply<?>>(){
    @Override public void messageReceived(    ChannelHandlerContext channelHandlerContext,    Reply<?> reply) throws Exception {
        write(ch);
    @Override public void operationComplete(    ChannelFuture channelFuture) throws Exception {
      write(ch);
}
messageReceived{
  if (i == CALLS) {
}
operationComplete{ }
